"""
app.conf.beat_schedule = {
    'task-name': {
        'task': 'tasks.task_function_name',  # 任务的完整路径
        'schedule': schedule_expression,      # 调度表达式
        'args': (arg1, arg2, ...),            # 可选，传递给任务的参数
        'kwargs': {'key': 'value'},           # 可选，传递给任务的关键字参数
    },
    # 可以定义多个任务
}
"""
from kombu import Queue
from celery.schedules import crontab


beat_schedule = {
    'print_msg': {
        'task': 'celery_tasks.tasks.beat_tasks.print_msg',
        'schedule': crontab(minute="*/1"),
    }
}

task_queues = (
    Queue("default", routing_key="default"),
    Queue("return_result", routing_key="return_result")
)

task_routes = {
    'celery_tasks.tasks.beat_tasks.print_msg': {
        "queue": "default",
        "routing_key": "default"
    }
}
